package speed2010.middleware;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

import speed2010.mensagem.Mensagem;

public class MsgQueue extends Thread {

	private BlockingQueue<Mensagem> bq = new LinkedBlockingQueue<Mensagem>();

	public void adicionaMsg(Mensagem msg) {
		this.bq.add(msg);
	}

	public Mensagem extraiMsg() {
		Mensagem msg = null;
		try {
			msg = this.bq.take();
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		return msg;
	}

	public boolean hasMsg() {
		return !this.bq.isEmpty();
	}
}
